package cn.tannn.cat.tmq.core;

/**
 * 消息生产者
 *
 * @author <a href="https://t.tannn.cn/">tnnn</a>
 * @version V1.0
 * @date 2024/7/7 下午1:39
 */
public class TProducer {

    /**
     * MQ中间人(代理商,管理 message queue
     */
    TBroker broker;

    /**
     * 发送消息
     * @param topic 消息主题
     * @param message 消息内容
     * @return
     */
    public boolean send(String topic, Message message){
        TMq mq = broker.find(topic);
        if(mq == null) throw new RuntimeException("topic not found");
        return mq.send(message);
    }

}
